package cn.itcast.mq.config;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

//@Configuration
public class CommonConfig {


    // 设置路由：
    @Bean
    public Queue queueBuilder(){
        new Queue("");

        // 使用QueueBuilder构建队列，durable就是持久化：
        return QueueBuilder.durable("simple.queue").build();
    }


    // 设置交换机：
    @Bean
    public DirectExchange exchange(){
        // 参数： 交换机的名称、是否持久化、当没有与Queue队列绑定时，是否自动删除
        return new DirectExchange("simple.direct");
    }
}
